

package org.pizza.rocket.core.listener;


import com.aliyun.openservices.ons.api.Message;

/**
 * @author 高巍
 * email kynb_club@163.com
 * @since 2020/11/23 3:36 下午
 * 普通
 */
public interface OrderRocketMQListener<T> {
    /**
     * 消息消费回调函数
     * @param message 消息
     */
    void onMessage(T message);
    /**
     * 消费异常回调函数
     * @param message
     * @param e
     */
    default void onError(Message message,T body, Exception e){};
    /**
     * 最大重试次数回调函数
     * @param message
     * @param body
     */
    default void onMaxRetry(Message message,T body){};

}
